--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
tests/backend/test_active_sessions.py e5756d7ab065475a18acdcafc008a767fcff87e0 (e5756d7a) Text, 10.47 KB
T8b949e# SPDX-License-Identifier: 0BSD
T8b949e"""Active UI WebSocket session tracking and multi-session warning oracles."""
Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations
Tff7b72import T7ee787json
Tff7b72import T7ee787shutil
Tff7b72import T7ee787tempfile
Tff7b72from T7ee787unittestT7ee787.T7ee787mock Tff7b72import Te6edf3AsyncMockTb4b4b4, Te6edf3MagicMockTb4b4b4, Te6edf3patch
Tff7b72import T7ee787pytest
Tff7b72import T7ee787RNS
Tff7b72from T7ee787hypothesis Tff7b72import Te6edf3givenTb4b4b4, Te6edf3settings
Tff7b72from T7ee787hypothesis Tff7b72import Te6edf3strategies Tff7b72as Te6edf3st
Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787active_sessions Tff7b72import Tb4b4b4(
Te6edf3ActiveSessionTrackerTb4b4b4,
Te6edf3should_warn_multi_sessionTb4b4b4,
Tb4b4b4)
Tf0883e@pytestTff7b72.Td2a8fffixture
Tff7b72def Td2a8fftemp_dirTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3dir_path Tff7b72= Te6edf3tempfileTff7b72.Td2a8ffmkdtempTb4b4b4(Tb4b4b4)
Tff7b72yield Te6edf3dir_path
Te6edf3shutilTff7b72.Td2a8ffrmtreeTb4b4b4(Te6edf3dir_pathTb4b4b4)
Tf0883e@pytestTff7b72.Td2a8fffixture
Tff7b72def Td2a8ffmock_rns_minimalTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72with Tb4b4b4(
Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffRNS.ReticulumTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3mock_rnsTb4b4b4,
Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffRNS.TransportTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffLXMF.LXMRouterTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.get_file_pathTa5d6ff"Tb4b4b4, Te6edf3return_valueTff7b72=Ta5d6ff"Ta5d6ff/tmp/mock_pathTa5d6ff"Tb4b4b4)Tb4b4b4,
Tb4b4b4)Tb4b4b4:
Te6edf3mock_rns_instance Tff7b72= Te6edf3mock_rnsTff7b72.Td2a8ffreturn_value
Te6edf3mock_rns_instanceTff7b72.Td2a8ffconfigpath Tff7b72= Ta5d6ff"Ta5d6ff/tmp/mock_configTa5d6ff"
Te6edf3mock_rns_instanceTff7b72.Td2a8ffis_connected_to_shared_instance Tff7b72= Tff7b72False
Te6edf3mock_rns_instanceTff7b72.Td2a8fftransport_enabledTff7b72.Td2a8ffreturn_value Tff7b72= Tff7b72True
Te6edf3mock_id Tff7b72= Te6edf3MagicMockTb4b4b4(Te6edf3specTff7b72=Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4)
Te6edf3mock_idTff7b72.Td2a8ffhash Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6fftest_hash_32_bytes_long_01234567Ta5d6ff"
Te6edf3mock_idTff7b72.Td2a8ffhexhash Tff7b72= Te6edf3mock_idTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)
Te6edf3mock_idTff7b72.Td2a8ffget_private_keyTff7b72.Td2a8ffreturn_value Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6fftest_private_keyTa5d6ff"
Tff7b72yield Te6edf3mock_id
Tff7b72def Td2a8fftest_should_warn_multi_session_oracle_edge_casesTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff0Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff1Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff2Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff3Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff2Tb4b4b4, Tff7b72FalseTb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(T79c0ff99Tb4b4b4, Tff7b72FalseTb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(Ta5d6ff"Ta5d6ff2Ta5d6ff"Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(Ta5d6ff"Ta5d6ffnopeTa5d6ff"Tb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(Tff7b72NoneTb4b4b4, Tff7b72TrueTb4b4b4) Tff7b72is Tff7b72False
Tf0883e@givenTb4b4b4(
Te6edf3countTff7b72=Te6edf3stTff7b72.Td2a8ffintegersTb4b4b4(Te6edf3min_valueTff7b72=Tff7b72-T79c0ff5Tb4b4b4, Te6edf3max_valueTff7b72=T79c0ff50Tb4b4b4)Tb4b4b4,
Te6edf3enabledTff7b72=Te6edf3stTff7b72.Td2a8ffbooleansTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tf0883e@settingsTb4b4b4(Te6edf3max_examplesTff7b72=T79c0ff80Tb4b4b4, Te6edf3deadlineTff7b72=Tff7b72NoneTb4b4b4)
Tff7b72def Td2a8fftest_should_warn_multi_session_matches_count_thresholdTb4b4b4(Te6edf3countTb4b4b4, Te6edf3enabledTb4b4b4)Tb4b4b4:
Te6edf3expected Tff7b72= Tffa657boolTb4b4b4(Te6edf3enabledTb4b4b4) Tff7b72and Tffa657intTb4b4b4(Te6edf3countTb4b4b4) Tff7b72>Tff7b72= T79c0ff2
Tff7b72assert Te6edf3should_warn_multi_sessionTb4b4b4(Te6edf3countTb4b4b4, Te6edf3enabledTb4b4b4) Tff7b72is Te6edf3expected
Tff7b72def Td2a8fftest_tracker_add_list_remove_round_tripTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3tracker Tff7b72= Te6edf3ActiveSessionTrackerTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff0
Tff7b72assert Te6edf3trackerTff7b72.Td2a8fflist_sessionsTb4b4b4(Tb4b4b4) Tff7b72== Tb4b4b4[Tb4b4b4]
Te6edf3first Tff7b72= Te6edf3trackerTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffBrowser/ATa5d6ff"Tb4b4b4)
Te6edf3second Tff7b72= Te6edf3trackerTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff10.0.0.2Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffBrowser/BTa5d6ff"Tb4b4b4)
Tff7b72assert Te6edf3firstTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4] Tff7b72!= Te6edf3secondTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff2
Te6edf3rows Tff7b72= Te6edf3trackerTff7b72.Td2a8fflist_sessionsTb4b4b4(Tb4b4b4)
Tff7b72assert Tffa657lenTb4b4b4(Te6edf3rowsTb4b4b4) Tff7b72== T79c0ff2
Tff7b72assert Te6edf3rowsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffipTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"
Tff7b72assert Te6edf3rowsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffBrowser/ATa5d6ff"
Tff7b72assert Te6edf3rowsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffipTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ff10.0.0.2Ta5d6ff"
Tff7b72assert Tffa657isinstanceTb4b4b4(Te6edf3rowsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffconnected_atTa5d6ff"Tb4b4b4]Tb4b4b4, Tffa657floatTb4b4b4)
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3firstTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]Tb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff1
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3firstTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]Tb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffremoveTb4b4b4(Ta5d6ff"Ta5d6ff"Tb4b4b4) Tff7b72is Tff7b72False
Tff7b72assert Te6edf3trackerTff7b72.Td2a8ffremoveTb4b4b4(Tff7b72NoneTb4b4b4) Tff7b72is Tff7b72False
Te6edf3snap Tff7b72= Te6edf3trackerTff7b72.Td2a8ffsnapshotTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3snapTb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff1
Tff7b72assert Te6edf3snapTb4b4b4[Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4] Tff7b72== Te6edf3secondTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Tff7b72def Td2a8fftest_tracker_sanitizes_ip_and_user_agentTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3tracker Tff7b72= Te6edf3ActiveSessionTrackerTb4b4b4(Tb4b4b4)
Te6edf3entry Tff7b72= Te6edf3trackerTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Tff7b72NoneTb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Tffea00\x00Tffea00\x01Ta5d6ffbadTffea00\x7fTa5d6ff agentTa5d6ff"Tb4b4b4)
Tff7b72assert Te6edf3entryTb4b4b4[Ta5d6ff"Ta5d6ffipTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffunknownTa5d6ff"
Tff7b72assert Ta5d6ff"Tffea00\x00Ta5d6ff" Tff7b72not Tff7b72in Te6edf3entryTb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4]
Tff7b72assert Ta5d6ff"Ta5d6ffbadTa5d6ff" Tff7b72in Te6edf3entryTb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4]
Te6edf3long_ua Tff7b72= Ta5d6ff"Ta5d6ffxTa5d6ff" Tff7b72* T79c0ff2000
Te6edf3long_ip Tff7b72= Ta5d6ff"Ta5d6ffyTa5d6ff" Tff7b72* T79c0ff200
Te6edf3entry2 Tff7b72= Te6edf3trackerTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Te6edf3long_ipTb4b4b4, Te6edf3user_agentTff7b72=Te6edf3long_uaTb4b4b4)
Tff7b72assert Tffa657lenTb4b4b4(Te6edf3entry2Tb4b4b4[Ta5d6ff"Ta5d6ffipTa5d6ff"Tb4b4b4]Tb4b4b4) Tff7b72<Tff7b72= T79c0ff128
Tff7b72assert Tffa657lenTb4b4b4(Te6edf3entry2Tb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4]Tb4b4b4) Tff7b72<Tff7b72= T79c0ff512
Tff7b72def Td2a8fftest_tracker_empty_user_agent_becomes_unknownTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3tracker Tff7b72= Te6edf3ActiveSessionTrackerTb4b4b4(Tb4b4b4)
Te6edf3entry Tff7b72= Te6edf3trackerTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff192.168.1.1Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ff Ta5d6ff"Tb4b4b4)
Tff7b72assert Te6edf3entryTb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffunknownTa5d6ff"
Tf0883e@pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffasyncio
Tff7b72async Tff7b72def Td2a8fftest_app_sessions_endpoint_smokeTb4b4b4(Te6edf3mock_rns_minimalTb4b4b4, Te6edf3temp_dirTb4b4b4)Tb4b4b4:
Tff7b72from T7ee787meshchatxT7ee787.T7ee787meshchat Tff7b72import Te6edf3ReticulumMeshChat
Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.generate_ssl_certificateTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3app Tff7b72= Te6edf3ReticulumMeshChatTb4b4b4(
Te6edf3identityTff7b72=Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3storage_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Te6edf3reticulum_config_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Tb4b4b4)
Te6edf3handler Tff7b72= Tff7b72None
Tff7b72for Te6edf3route Tff7b72in Te6edf3appTff7b72.Td2a8ffget_routesTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72if Te6edf3routeTff7b72.Td2a8ffpath Tff7b72== Ta5d6ff"Ta5d6ff/api/v1/app/sessionsTa5d6ff" Tff7b72and Te6edf3routeTff7b72.Td2a8ffmethod Tff7b72== Ta5d6ff"Ta5d6ffGETTa5d6ff"Tb4b4b4:
Te6edf3handler Tff7b72= Te6edf3routeTff7b72.Td2a8ffhandler
Tff7b72break
Tff7b72assert Te6edf3handler Tff7b72is Tff7b72not Tff7b72None
Te6edf3response Tff7b72= Tff7b72await Te6edf3handlerTb4b4b4(Te6edf3MagicMockTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3data Tff7b72= Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3responseTff7b72.Td2a8ffbodyTb4b4b4)
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff0
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4] Tff7b72== Tb4b4b4[Tb4b4b4]
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72False
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffwarning_enabledTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Te6edf3first Tff7b72= Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffA/1Ta5d6ff"Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff10.0.0.5Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffB/2Ta5d6ff"Tb4b4b4)
Te6edf3response Tff7b72= Tff7b72await Te6edf3handlerTb4b4b4(Te6edf3MagicMockTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3data Tff7b72= Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3responseTff7b72.Td2a8ffbodyTb4b4b4)
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff2
Tff7b72assert Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Tff7b72assert Tb4b4b4{Te6edf3rowTb4b4b4[Ta5d6ff"Ta5d6ffipTa5d6ff"Tb4b4b4] Tff7b72for Te6edf3row Tff7b72in Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4]Tb4b4b4} Tff7b72== Tb4b4b4{Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ff10.0.0.5Ta5d6ff"Tb4b4b4}
Tff7b72assert Tb4b4b4{Te6edf3rowTb4b4b4[Ta5d6ff"Ta5d6ffuser_agentTa5d6ff"Tb4b4b4] Tff7b72for Te6edf3row Tff7b72in Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4]Tb4b4b4} Tff7b72== Tb4b4b4{Ta5d6ff"Ta5d6ffA/1Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffB/2Ta5d6ff"Tb4b4b4}
Tff7b72assert Tffa657anyTb4b4b4(Te6edf3rowTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4] Tff7b72== Te6edf3firstTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4] Tff7b72for Te6edf3row Tff7b72in Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4]Tb4b4b4)
Tf0883e@pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffasyncio
Tff7b72async Tff7b72def Td2a8fftest_multi_session_warning_setting_in_config_and_payloadTb4b4b4(
Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3temp_dirTb4b4b4,
Tb4b4b4)Tb4b4b4:
Tff7b72from T7ee787meshchatxT7ee787.T7ee787meshchat Tff7b72import Te6edf3ReticulumMeshChat
Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.generate_ssl_certificateTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3app Tff7b72= Te6edf3ReticulumMeshChatTb4b4b4(
Te6edf3identityTff7b72=Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3storage_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Te6edf3reticulum_config_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Tb4b4b4)
Tff7b72assert Te6edf3appTff7b72.Td2a8ffconfigTff7b72.Td2a8ffmulti_session_warning_enabledTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3appTff7b72.Td2a8ffget_config_dictTb4b4b4(Tb4b4b4)Tb4b4b4[Ta5d6ff"Ta5d6ffmulti_session_warning_enabledTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff1.1.1.1Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffoneTa5d6ff"Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff2.2.2.2Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6fftwoTa5d6ff"Tb4b4b4)
Te6edf3payload Tff7b72= Te6edf3appTff7b72.Td2a8ffget_active_sessions_payloadTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3payloadTb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Te6edf3appTff7b72.Td2a8ffconfigTff7b72.Td2a8ffmulti_session_warning_enabledTff7b72.Td2a8ffsetTb4b4b4(Tff7b72FalseTb4b4b4)
Te6edf3payload Tff7b72= Te6edf3appTff7b72.Td2a8ffget_active_sessions_payloadTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3payloadTb4b4b4[Ta5d6ff"Ta5d6ffwarning_enabledTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72False
Tff7b72assert Te6edf3payloadTb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72False
Te6edf3appTff7b72.Td2a8ffconfigTff7b72.Td2a8ffmulti_session_warning_enabledTff7b72.Td2a8ffsetTb4b4b4(Tff7b72TrueTb4b4b4)
Tff7b72with Tb4b4b4(
Te6edf3patchTff7b72.Td2a8ffobjectTb4b4b4(Te6edf3appTb4b4b4, Ta5d6ff"Ta5d6ffsend_config_to_websocket_clientsTa5d6ff"Tb4b4b4, Te6edf3new_callableTff7b72=Te6edf3AsyncMockTb4b4b4)Tb4b4b4,
Te6edf3patchTff7b72.Td2a8ffobjectTb4b4b4(
Te6edf3appTb4b4b4,
Ta5d6ff"Ta5d6ffsend_active_sessions_to_websocket_clientsTa5d6ff"Tb4b4b4,
Te6edf3new_callableTff7b72=Te6edf3AsyncMockTb4b4b4,
Tb4b4b4) Tff7b72as Te6edf3sessions_broadcastTb4b4b4,
Tb4b4b4)Tb4b4b4:
Tff7b72await Te6edf3appTff7b72.Td2a8ffupdate_configTb4b4b4(Tb4b4b4{Ta5d6ff"Ta5d6ffmulti_session_warning_enabledTa5d6ff"Tb4b4b4: Tff7b72FalseTb4b4b4}Tb4b4b4)
Tff7b72assert Te6edf3appTff7b72.Td2a8ffconfigTff7b72.Td2a8ffmulti_session_warning_enabledTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4) Tff7b72is Tff7b72False
Te6edf3sessions_broadcastTff7b72.Td2a8ffassert_awaitedTb4b4b4(Tb4b4b4)
Tf0883e@pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffasyncio
Tff7b72async Tff7b72def Td2a8fftest_detach_active_session_and_broadcast_payloadTb4b4b4(Te6edf3mock_rns_minimalTb4b4b4, Te6edf3temp_dirTb4b4b4)Tb4b4b4:
Tff7b72from T7ee787meshchatxT7ee787.T7ee787meshchat Tff7b72import Te6edf3ReticulumMeshChat
Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.generate_ssl_certificateTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3app Tff7b72= Te6edf3ReticulumMeshChatTb4b4b4(
Te6edf3identityTff7b72=Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3storage_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Te6edf3reticulum_config_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Tb4b4b4)
Te6edf3entry Tff7b72= Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff::1Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffUATa5d6ff"Tb4b4b4)
Te6edf3client Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)
Te6edf3clientTff7b72.Td2a8ff_meshchatx_session_id Tff7b72= Te6edf3entryTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Tff7b72assert Te6edf3appTff7b72.Td2a8ff_detach_active_sessionTb4b4b4(Te6edf3clientTb4b4b4) Tff7b72is Tff7b72True
Tff7b72assert Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff0
Tff7b72assert Tff7b72not Tffa657hasattrTb4b4b4(Te6edf3clientTb4b4b4, Ta5d6ff"Ta5d6ff_meshchatx_session_idTa5d6ff"Tb4b4b4)
Tff7b72assert Te6edf3appTff7b72.Td2a8ff_detach_active_sessionTb4b4b4(Te6edf3clientTb4b4b4) Tff7b72is Tff7b72False
Te6edf3sent Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72async Tff7b72def Td2a8ffcaptureTb4b4b4(Te6edf3dataTb4b4b4)Tb4b4b4:
Te6edf3sentTff7b72.Td2a8ffappendTb4b4b4(Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3dataTb4b4b4)Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffwebsocket_broadcast Tff7b72= Te6edf3capture
Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff8.8.8.8Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffChromeTa5d6ff"Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff9.9.9.9Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffFirefoxTa5d6ff"Tb4b4b4)
Tff7b72await Te6edf3appTff7b72.Td2a8ffsend_active_sessions_to_websocket_clientsTb4b4b4(Tb4b4b4)
Tff7b72assert Tffa657lenTb4b4b4(Te6edf3sentTb4b4b4) Tff7b72== T79c0ff1
Tff7b72assert Te6edf3sentTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffapp.sessions.updatedTa5d6ff"
Tff7b72assert Te6edf3sentTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff2
Tff7b72assert Te6edf3sentTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Tf0883e@pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffasyncio
Tff7b72async Tff7b72def Td2a8fftest_websocket_broadcast_detaches_dead_sessionTb4b4b4(Te6edf3mock_rns_minimalTb4b4b4, Te6edf3temp_dirTb4b4b4)Tb4b4b4:
Tff7b72from T7ee787meshchatxT7ee787.T7ee787meshchat Tff7b72import Te6edf3ReticulumMeshChat
Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.generate_ssl_certificateTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3app Tff7b72= Te6edf3ReticulumMeshChatTb4b4b4(
Te6edf3identityTff7b72=Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3storage_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Te6edf3reticulum_config_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Tb4b4b4)
Te6edf3live Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)
Te6edf3liveTff7b72.Td2a8ffsend_str Tff7b72= Te6edf3AsyncMockTb4b4b4(Tb4b4b4)
Te6edf3liveTff7b72.Td2a8ffclose Tff7b72= Te6edf3AsyncMockTb4b4b4(Tb4b4b4)
Te6edf3dead Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)
Te6edf3deadTff7b72.Td2a8ffsend_str Tff7b72= Te6edf3AsyncMockTb4b4b4(Te6edf3side_effectTff7b72=Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffgoneTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3deadTff7b72.Td2a8ffclose Tff7b72= Te6edf3AsyncMockTb4b4b4(Tb4b4b4)
Te6edf3dead_entry Tff7b72= Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff10.0.0.9Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffDead/1Ta5d6ff"Tb4b4b4)
Te6edf3deadTff7b72.Td2a8ff_meshchatx_session_id Tff7b72= Te6edf3dead_entryTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Te6edf3live_entry Tff7b72= Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Ta5d6ff"Ta5d6ff10.0.0.8Ta5d6ff"Tb4b4b4, Te6edf3user_agentTff7b72=Ta5d6ff"Ta5d6ffLive/1Ta5d6ff"Tb4b4b4)
Te6edf3liveTff7b72.Td2a8ff_meshchatx_session_id Tff7b72= Te6edf3live_entryTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Te6edf3appTff7b72.Td2a8ffwebsocket_clients Tff7b72= Tb4b4b4[Te6edf3liveTb4b4b4, Te6edf3deadTb4b4b4]
T8b949e# Avoid recursive session broadcast while asserting detach bookkeeping.
Te6edf3appTff7b72.Td2a8ffsend_active_sessions_to_websocket_clients Tff7b72= Te6edf3AsyncMockTb4b4b4(Tb4b4b4)
Tff7b72await Te6edf3appTff7b72.Td2a8ffwebsocket_broadcastTb4b4b4(Ta5d6ff'Ta5d6ff{Ta5d6ff"Ta5d6fftypeTa5d6ff"Ta5d6ff:Ta5d6ff"Ta5d6ffpingTa5d6ff"Ta5d6ff}Ta5d6ff'Tb4b4b4)
Tff7b72assert Te6edf3dead Tff7b72not Tff7b72in Te6edf3appTff7b72.Td2a8ffwebsocket_clients
Tff7b72assert Te6edf3live Tff7b72in Te6edf3appTff7b72.Td2a8ffwebsocket_clients
Tff7b72assert Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff1
Tff7b72assert Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8fflist_sessionsTb4b4b4(Tb4b4b4)Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4] Tff7b72== Te6edf3live_entryTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Te6edf3appTff7b72.Td2a8ffsend_active_sessions_to_websocket_clientsTff7b72.Td2a8ffassert_awaitedTb4b4b4(Tb4b4b4)
Tf0883e@pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffasyncio
Tff7b72async Tff7b72def Td2a8fftest_connect_disconnect_session_lifecycle_unitTb4b4b4(Te6edf3mock_rns_minimalTb4b4b4, Te6edf3temp_dirTb4b4b4)Tb4b4b4:
T8b949e"""Simulate the connect and disconnect bookkeeping without a live aiohttp WS."""
Tff7b72from T7ee787meshchatxT7ee787.T7ee787meshchat Tff7b72import Te6edf3ReticulumMeshChat
Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.generate_ssl_certificateTa5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3app Tff7b72= Te6edf3ReticulumMeshChatTb4b4b4(
Te6edf3identityTff7b72=Te6edf3mock_rns_minimalTb4b4b4,
Te6edf3storage_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Te6edf3reticulum_config_dirTff7b72=Te6edf3temp_dirTb4b4b4,
Tb4b4b4)
Te6edf3broadcasts Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72async Tff7b72def Td2a8ffcaptureTb4b4b4(Te6edf3dataTb4b4b4)Tb4b4b4:
Te6edf3broadcastsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3dataTb4b4b4)Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffwebsocket_broadcast Tff7b72= Te6edf3capture
Te6edf3clients Tff7b72= Tb4b4b4[Tb4b4b4]
Tff7b72for Te6edf3ipTb4b4b4, Te6edf3ua Tff7b72in Tb4b4b4(Tb4b4b4(Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffOneTa5d6ff"Tb4b4b4)Tb4b4b4, Tb4b4b4(Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffTwoTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3client Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)
Te6edf3session Tff7b72= Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffaddTb4b4b4(Te6edf3ipTff7b72=Te6edf3ipTb4b4b4, Te6edf3user_agentTff7b72=Te6edf3uaTb4b4b4)
Te6edf3clientTff7b72.Td2a8ff_meshchatx_session_id Tff7b72= Te6edf3sessionTb4b4b4[Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4]
Te6edf3appTff7b72.Td2a8ffwebsocket_clientsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3clientTb4b4b4)
Te6edf3clientsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3clientTb4b4b4)
Tff7b72await Te6edf3appTff7b72.Td2a8ffsend_active_sessions_to_websocket_clientsTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff2
Tff7b72assert Te6edf3broadcastsTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72True
Tff7b72assert Te6edf3broadcastsTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff2
Te6edf3client Tff7b72= Te6edf3clientsTff7b72.Td2a8ffpopTb4b4b4(Tb4b4b4)
Te6edf3appTff7b72.Td2a8ffwebsocket_clientsTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3clientTb4b4b4)
Te6edf3appTff7b72.Td2a8ff_detach_active_sessionTb4b4b4(Te6edf3clientTb4b4b4)
Tff7b72await Te6edf3appTff7b72.Td2a8ffsend_active_sessions_to_websocket_clientsTb4b4b4(Tb4b4b4)
Tff7b72assert Te6edf3appTff7b72.Td2a8ffactive_sessionsTff7b72.Td2a8ffcountTb4b4b4(Tb4b4b4) Tff7b72== T79c0ff1
Tff7b72assert Te6edf3broadcastsTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffwarningTa5d6ff"Tb4b4b4] Tff7b72is Tff7b72False
Tff7b72assert Te6edf3broadcastsTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72== T79c0ff1
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────